package com.example.demo.service;

import com.example.demo.Constant;
import com.example.demo.po.WiselyResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * 功能描述:
 * 版本信息:   Copyright (c)2017
 * 公司信息:   杭州佐通科技有限公司
 * 开发人员:   Created by xiaochuan
 * 版本日志:   1.0
 * 创建日期:   2018/5/14
 * 创建时间：  11:29
 * 修改历史:
 * 时间         开发者      版本号    修改内容
 * ------------------------------------------------------------------
 * 2018/5/14    xiaochuan      1.0         1.0 Version
 */
@Service("webSocketService")
public class WebSocketService {
    @Autowired
    private SimpMessagingTemplate template;

    /**
     * 广播
     * 发给所有在线用户
     *
     * @param msg
     */
    public void sendMsg(WiselyResponse msg) {
        template.convertAndSend(Constant.PRODUCERPATH, msg);
    }

    /**
     * 发送给指定用户
     * @param users
     * @param msg
     */
    public void send2Users(List<String> users, WiselyResponse msg) {
        users.forEach(userName -> {
            System.out.println("============="+users.size());
            System.out.println("============="+msg.getResponseMessage());
            template.convertAndSendToUser(userName, Constant.P2PPUSHPATH, "回复客户端"+msg);
        });
    }
}
